package Test;

import com.udf.flink.udsf.StrUdf;

/**
 * @author tieyi  2019/12/21 23:22
 * @version 1.0.0
 * @Description: No Description
 * @package Test
 * @file Flink_UDF_Demo
 */
public class Test {
    public static void main(String[] args) throws Exception {
//        String path = "C:\\Users\\10524\\Desktop\\实时股份资金变动-贴源层\\job\\sinkTable.sql";
//        AuoToCTable cTable = new AuoToCTable();
//        SQLReader sqlReader = new SQLReader();
//        cTable.init();
//        System.out.println(sqlReader.readSQLFileByBytes(path));
//        String s = cTable.CreateOracleTable(sqlReader.readSQLFileByBytes(path));
//        System.out.println(s);
        StrUdf u= new StrUdf();
        System.out.println(u.eval("gfdsfsdg",2,7));
    }
}
